package scheduler

import (
	"go-fox-edge-persist/entityAdapter"
)

var (
	valueScheduler       *RedisListValueScheduler
	recordScheduler      *RedisListRecordScheduler
	manageScheduler      *RedisListManageScheduler
	taskScheduler        *PersistManageScheduler
	DeviceHistoryAdapter entityAdapter.IDeviceHistoryAdapter
	OperateRecordAdapter entityAdapter.IOperateRecordAdapter
)

func init() {
	valueScheduler = &RedisListValueScheduler{}
	recordScheduler = &RedisListRecordScheduler{}
	manageScheduler = &RedisListManageScheduler{}
}

// Scheduler 线程函数
func Scheduler() {
	taskScheduler.Scheduler()
	valueScheduler.Scheduler()
	recordScheduler.Scheduler()
	manageScheduler.Scheduler()
}
